package com.wyp168.socket.QQ.qqclient.services;

import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

/**
 * @ClassName ManagerClientConnectServerThread
 * @Title 管理客户端与服务端连接的线程集合
 * @Author wyp168
 * @Date 2022/10/30 15:25
 */
public class ManagerClientConnectServerThread {
    //把多个线程类 放入一个HashMap集合中， key 就是用户id， value 就是线程
    private static Map<String, ClientConnectServerThread> tm = new ConcurrentHashMap<>();

    //将某个线程加入到集合
    public static void addClientConnectServerThread(String userId, ClientConnectServerThread thread) {
        tm.put(userId, thread);
    }

    //通过userId，获取得到对应线程
    public static ClientConnectServerThread getClientConnectServerThread(String userId) {
        return tm.get(userId);
    }
}
